--[[ 编码: JX-24-16 名称: 出库单-拣料箱绑定界面-确定 作者： 日期：2025-1-29 函数： main 功能: -- 创建出库波次，把拣货箱绑定到 出库单 更改记录: V2.0 HAN 20241024 参数改成从 m3.GetSysInputParameter( strLuaDEID ) 获取 一个出库单也形成出库波次 V3.0 HAN 20241026 触发一个后台 WFP 进行配盘操作 --]] wms_base = require ("wms_base") function main( strLuaDEID ) local nRet, strRetInfo local parameter nRet, parameter = m3.GetSysInputParameter( strLuaDEID ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "m3.GetSysInputParameter 失败! "..parameter ) end lua.Debug( strLuaDEID, debug.getinfo(1), "parameter", parameter ) local total_qty = 0 -- 货品种类 local ipa_item_list = {} -- 预分配库存时用到 local sum_detail_list = parameter.o_detail_list local bWave = false local compose = parameter.wave_compose local wh_code = parameter.wh_code local area_code = parameter.area_code local station = parameter.station local exit_loc = parameter.exit_loc local login = parameter.login local user_name = parameter.user_name local nCount = #compose nRet, strRetInfo = mobox.getCurEditDataObjAttr( strLuaDEID, "PickingBoxCode", "PickingBoxNum" ) local input_value = json.decode( strRetInfo ) local picking_box_codes = lua.Get_StrAttrValue( input_value[1].value ) if ( picking_box_codes == '' ) then mobox.stopProgram( strLuaDEID, "必须绑定拣料箱!") return end -- 拣料箱数量 local picking_box_num = lua.Get_NumAttrValue( input_value[2].value ) if ( picking_box_num <= 0 ) then mobox.stopProgram( strLuaDEID, "拣料箱数量不合法!") return end local pick_box_code_array = lua.split( picking_box_codes, ";" ) if ( #pick_box_code_array ~= picking_box_num ) then mobox.stopProgram( strLuaDEID, "绑定的拣料箱数量必须="..picking_box_num) return end local good_type_num = #sum_detail_list -- 【step1】 申请分配量，判断库存量是否够出库 for n = 1, good_type_num do local ipa_item = { N_ROW_NO = n, S_ITEM_CODE = sum_detail_list[n].item_code, S_ITEM_NAME = sum_detail_list[n].item_name, F_QTY = sum_detail_list[n].qty } table.insert( ipa_item_list, ipa_item ) end -- IPA 库存量分配开始 nRet, strRetInfo = wms.wms_IPA_Start( wh_code, "", lua.table2str(ipa_item_list) ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_IPA_Start 失败!"..strRetInfo ) end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then mobox.setInfo( strLuaDEID, "wms_IPA_Start 返回值不正确! --> "..strRetInfo ) return end if ( ret_info.trans_id == "" ) then -- 缺件 -- 这里加一个HTML弹框 mobox.setInfo( strLuaDEID, "缺件! --> "..lua.table2str( ret_info.oos_info ) ) return end local ipa_transid = ret_info.trans_id -- 【step2】 初始化出库货品清单 item_list local item_list = {} local obj_attrs -- 生成要出库的货品链表 item_list for n = 1, good_type_num do local item = { item_code = sum_detail_list[n].item_code, item_name = sum_detail_list[n].item_name, volume = sum_detail_list[n].volume, weight = sum_detail_list[n].weight, cell_type = sum_detail_list[n].cell_type, qty = sum_detail_list[n].qty, alloc_qty = 0, cntr_cell_list = {}, ok = false -- true 表示这个货品已经配完货 } table.insert( item_list, item ) end -- 【step3】 如果是波次出库，系统生成出库波次对象（需要用波次号区锁定容器） local strUpdateSql local oo_no_set = {} local wave_detail local wave -- 创建出库波次 wave = m3.AllocObject(strLuaDEID,"Outbound_Wave") wave.wh_code = wh_code wave.area_code = area_code wave.station = station wave.operator_name = user_name wave.operator = login wave.good_type_num = parameter.good_type_num wave.total_qty = parameter.total_qty wave.picking_box_num = parameter.picking_box_num nRet, wave = m3.CreateDataObj( strLuaDEID, wave ) if ( nRet ~= 0 ) then wms.wms_IPA_Abort( ipa_transid ) lua.Error( strLuaDEID, debug.getinfo(1), '创建【出库波次】对象失败!'..wave ) end -- 创建出库波次组成 local nCurCodeIndex = 1 -- 拣料箱编码游标 local pick_box_code local m local pickbox_index = 1 -- compose 是组成波次的出库单的一些基础信息 -- nCount 出库单数量，创建波次组成 for n = 1, nCount do table.insert( oo_no_set, compose[n].oo_no ) local ow_compose = m3.AllocObject(strLuaDEID,"OW_Compose") ow_compose.oo_no = compose[n].oo_no ow_compose.wave_no = wave.wave_no nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, ow_compose ) if ( nRet ~= 0 ) then wms.wms_IPA_Abort( ipa_transid ) lua.Error( strLuaDEID, debug.getinfo(1), '创建【出库波次组成】对象失败!'..strRetInfo ) end -- 获取和该出库单进行绑定的拣料箱编码 pick_box_code = '' for m = 1, compose[n].pick_box_num do if (pick_box_code ~= '') then pick_box_code = pick_box_code..";" end pick_box_code = pick_box_code..pick_box_code_array[pickbox_index] pickbox_index = pickbox_index + 1 end strUpdateSql = "S_WAVE_NO = '"..wave.wave_no.."', S_STATION_NO = '"..wave.station.."', S_OPERATOR_NAME = '"..wave.operator_name.."'," -- 更新【出库单】状态, 并且把拣料箱绑定 -- N_B_STATE = 1 表示出库单已经配货 strUpdateSql = strUpdateSql.."S_OPERATOR = '"..wave.operator.."', N_B_STATE = 1, S_PICK_BOX_CODE = '"..pick_box_code.."'" strCondition = "S_NO = '"..compose[n].oo_no.."'" nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Outbound_Order", strCondition, strUpdateSql ) if ( nRet ~= 0 ) then wms.wms_IPA_Abort( ipa_transid ) lua.Error( strLuaDEID, debug.getinfo(1), "更新【出库单】信息失败!"..strRetInfo ) end end -- 创建出库波次明细 for n = 1, #sum_detail_list do wave_detail = m3.AllocObject(strLuaDEID,"OW_Detail") wave_detail.wave_no = wave.wave_no wave_detail.row_no = n wave_detail.item_code = sum_detail_list[n].item_code wave_detail.item_name = sum_detail_list[n].item_name wave_detail.qty = sum_detail_list[n].qty wave_detail.weight = sum_detail_list[n].weight wave_detail.volume = sum_detail_list[n].volume nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, wave_detail ) if ( nRet ~= 0 ) then wms.wms_IPA_Abort( ipa_transid ) lua.Error( strLuaDEID, debug.getinfo(1), '创建【出库波次明细】对象失败!'..strRetInfo ) end end -- 需要清空 拣料箱中的货品明细 CG_Detail local in_cntr_code = '' for n = 1, #pick_box_code_array do in_cntr_code = in_cntr_code.."'"..pick_box_code_array[n].."'," end in_cntr_code = lua.trim_laster_char( in_cntr_code ) -- 取消最后一个,号 strCondition = "S_CNTR_CODE IN ("..in_cntr_code..")" lua.Debug( strLuaDEID, debug.getinfo(1), "清除拣料箱CG_Detail--->", strCondition ) nRet, strRetInfo = mobox.dbdeleteData(strLuaDEID, "CG_Detail", strCondition) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "删除【CG_Detail】失败!"..strRetInfo) end -- 新增一个后台处理，让后台程序进行自动配盘 local add_wfp = { wfp_type = 1, -- 触发数据对象事件（指定数据对象标识） cls = "Outbound_Wave", obj_id = wave.id, obj_name = "波次号'"..wave.wave_no.."'-->自动配盘", trigger_event = "自动配盘" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then wms.wms_IPA_Abort( ipa_transid ) lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end wms.wms_IPA_Commit( ipa_transid ) local action = { { action_type = "close_dlg", value = "" }, { action_type = "refresh", value = "" } } nRet, strRetInfo = mobox.setAction( strLuaDEID, lua.table2str(action) ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "setAction失败! "..strRetInfo..' action = '..strAction ) end end